package org.dromara.common.websocket.listener;

import cn.hutool.core.collection.CollUtil;
import lombok.extern.slf4j.Slf4j;
import org.dromara.common.websocket.holder.WebSocketSessionHolder;
import org.dromara.common.websocket.utils.WebSocketUtils;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.core.Ordered;


/**
 * @Author 刘武贵
 * @Date 2024/8/15 22:00
 * @Description 功能描述：WebSocket 主题订阅监听器
 */
/**
 * WebSocket主题监听器类，实现ApplicationRunner和Ordered接口
 * 该类用于在应用程序启动时运行，以及在Bean初始化之前按指定顺序执行相关逻辑
 * 它的主要职责是监听和处理WebSocket主题的消息
 */
@Slf4j
public class WebSocketTopicListener implements ApplicationRunner, Ordered {

    /**
     * 在Spring Boot应用程序启动时初始化WebSocket主题订阅监听器
     * 启动时初始化WebSocket消息订阅监听器
     * <p>
     * 该方法在应用程序运行时被调用，用于设置WebSocket消息的订阅和处理逻辑
     * 它实现了ApplicationRunner接口的run方法，用于在Spring Boot应用启动后执行特定逻辑
     *
     * @param args 应用程序参数
     * @throws Exception 初始化过程中可能抛出的异常
     */
    @Override
    public void run(ApplicationArguments args) throws Exception {
        // 订阅WebSocket消息
        WebSocketUtils.subscribeMessage((message) -> {
            log.info("WebSocket主题订阅收到消息session keys={} message={}", message.getSessionKeys(), message.getMessage());
            // 如果key不为空就按照key发消息 如果为空就群发
            // 根据消息中携带的session keys决定消息发送的范围
            // 如果key不为空就按照key发消息 如果为空就群发
            if (CollUtil.isNotEmpty(message.getSessionKeys())) {
                message.getSessionKeys().forEach(key -> {
                    // 检查是否存在目标session
                    if (WebSocketSessionHolder.existSession(key)) {
                        // 向特定session发送消息
                        WebSocketUtils.sendMessage(key, message.getMessage());
                    }
                });
            } else {
                // 遍历所有sessions发送消息
                WebSocketSessionHolder.getSessionsAll().forEach(key -> {
                    WebSocketUtils.sendMessage(key, message.getMessage());
                });
            }
        });
        log.info("初始化WebSocket主题订阅监听器成功");
    }

    /**
     * 重写获取排序值的方法
     * 该方法在当前实现中的返回值为-1，用于指示该元素在排序时不考虑
     *
     * @return int 返回-1，表示该元素不参与排序
     */
    @Override
    public int getOrder() {
        return -1;
    }
}
